aboutsummaryrefslogtreecommitdiffstats
path: root/src/routes/(app)/ln/[lnurl]/+page.server.ts
blob: bd5e0cfa184e9025fbf1567d676515ff6a80fffa (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
import { PUBLIC_DOMAIN } from "$env/static/public";
import getRates from "$lib/rates";
import { auth, fd, get, post } from "$lib/utils";
import { bech32 } from "@scure/base";
import { error, fail, redirect } from "@sveltejs/kit";
const { decode, fromWords } = bech32;

export async function load({ params, parent }) {
	const { user } = await parent();
	const rates = await getRates();

	let data;
	const { lnurl } = params;

	const url = Buffer.from(fromWords(decode(lnurl, 20000).words)).toString();

	try {
		data = await get(`/decode?text=${lnurl}`);
	} catch (e) {
		const { message } = e as Error;
		error(500, message);
	}

	let { callback, minSendable, maxSendable, comment, tag } = data;
	if (tag === "payRequest" && minSendable === maxSendable) {
		minSendable = Math.round(minSendable / 1000);
		maxSendable = Math.round(maxSendable / 1000);
		const amount = minSendable;

		const urlObj = new URL(callback);
		urlObj.searchParams.set("amount", (amount * 1000).toString());
		if (comment) {
			urlObj.searchParams.set("comment", comment);
		}
		const url = urlObj.toString();

		const { pr } = await fetch(url).then((r) => (r as Response).json());

		let invoice;
		try {
			invoice = await get(`/invoice/${pr}`);
		} catch (e) {}

		if (invoice) redirect(307, `/invoice/${invoice.id}`);

		let path = `/send/lightning/${pr}`;
		if (comment) path += `/${encodeURIComponent(comment)}`;
		redirect(307, path);
	} else if (url.startsWith(`https://${PUBLIC_DOMAIN}/`)) {
		const username = url.split(`https://${PUBLIC_DOMAIN}/p/`)[1];
		if (username) redirect(307, `/pay/${username}`);
	}

	if (!["payRequest", "withdrawRequest"].includes(data.tag))
		error(500, "We only support LNURLp and LNURLw at this time");

	data.rate = rates[user?.currency || "USD"];
	return data;
}

export const actions = {
	pay: async ({ fetch, request }) => {
		let error;

		let { callback, amount, minSendable, maxSendable, comment } =
			await fd(request);
		minSendable = Math.round(minSendable / 1000);
		maxSendable = Math.round(maxSendable / 1000);

		if (amount < minSendable)
			error = `Amount must be at least ${minSendable} sats`;
		if (amount > maxSendable)
			error = `Amount must be at most ${maxSendable} sats`;
		if (error) return fail(400, { error });

		let url = `${callback}?amount=${amount * 1000}`;
		if (comment) url += `&comment=${comment}`;

		const { pr } = await fetch(url).then((r) => r.json());

		let path = `/send/lightning/${pr}`;
		if (comment) path += `/${encodeURIComponent(comment)}`;
		redirect(307, path);
	},

	withdraw: async ({ cookies, fetch, request }) => {
		let error;

		let {
			callback,
			amount,
			username,
			currency,
			minWithdrawable,
			maxWithdrawable,
			k1,
		} = await fd(request);

		minWithdrawable = Math.round(minWithdrawable / 1000);
		maxWithdrawable = Math.round(maxWithdrawable / 1000);

		if (amount < minWithdrawable)
			error = `Amount must be at least ${minWithdrawable} sats`;
		if (amount > maxWithdrawable)
			error = `Amount must be at most ${maxWithdrawable} sats`;
		if (error) return fail(400, { error });

		const invoice = { amount, type: "lightning" };
		const user = { username, currency };

		const { text: pr } = await post(
			"/invoice",
			{ invoice, user },
			auth(cookies),
		);

		const url = new URL(callback);
		url.searchParams.append("k1", k1);
		url.searchParams.append("pr", pr);

		await fetch(url.toString());

		redirect(307, "/payments");
	},
};